package com.muchfish.reactor.api;

import reactor.core.publisher.Flux;

public class ReactorCheckpointExample {
    public static void main(String[] args) {
        Flux<Integer> source = Flux.range(1, 5);

        // 在操作链中设置断点
        source.checkpoint("Initial Source")
                .map(x -> x * 2)
                .checkpoint("Mapped Source")
                .subscribe(System.out::println);
    }
}



